ab96dd8af3db2d9251420f6fc51bda5bdf2a8d1d,java/src/org/exist/jms/replication/publish/ReplicationTrigger.java,ReplicationTrigger,afterDeleteDocument,#DBBroker#Txn#XmldbURI#,219

Before Change


    @Override
    public void afterDeleteDocument(final DBBroker broker, final Txn transaction, final XmldbURI uri) throws TriggerException {

        if (LOGGER.isDebugEnabled()) {
            LOGGER.debug(uri.toString());
        }

        if (isJMSOrigin(transaction)) {
            LOGGER.info(String.format(BLOCKED_MESSAGE, uri.toString()));
            return;
        }

After Change


    @Override
    public void afterDeleteDocument(final DBBroker broker, final Txn transaction, final XmldbURI uri) throws TriggerException {

        LOGGER.info("Delete document '{}'", uri.toString());

        if (!guard.getReplicationEnabled()) {
            LOGGER.info(REPLICATION_OFF);
            return;
        }

        if (isJMSOrigin(transaction)) {
            LOGGER.info(BLOCKED_MESSAGE, uri.toString());
            return;
        }